package org.lk.entity;

import com.baomidou.mybatisplus.annotation.IdType;
import com.baomidou.mybatisplus.annotation.TableField;
import com.baomidou.mybatisplus.annotation.TableId;
import com.baomidou.mybatisplus.annotation.TableName;

import java.io.Serializable;

import com.fasterxml.jackson.annotation.JsonFormat;
import lombok.Data;

/**
 * @TableName cdc_job
 */
@TableName(value = "cdc_job")
@Data
public class CdcJob extends BaseEntity implements Serializable {
    /**
     *
     */
    @TableId
    private String id;

    /**
     * 任务名称
     */
    private String jobName;


    /**
     * 原表数据源ID
     */
    private String originDsId;

    /**
     * 原表数据源名称
     */
    private String originDsName;

    /**
     * 目的表数据源ID
     */
    private String targetDsId;

    /**
     * 目的表数据源名称
     */
    private String targetDsName;

    /**
     * 读取数据并行度
     */
    private Integer readParallelism;

    /**
     * 写入数据并行度
     */
    private Integer writerParallelism;

    /**
     * 是否是全表读取0为false 1为true子表应该写成*
     */
    private Boolean hasAllTable;

    /**
     * 是否是第一次读取
     */
    private Boolean hasFirstSync;
    /**
     * 保存点的位置
     */
    private String savePoint;

    /**
     * binlog文件名称
     */
    private String binlogFileName;


    private String jobId;

    @TableField(exist = false)
    private static final long serialVersionUID = 1L;
}